//package com.market.goods.web;
//
//import com.github.pagehelper.PageHelper;
//import com.github.pagehelper.PageInfo;
//import com.market.goods.constance.SuperRandom;
//import com.market.goods.dao.mapper.MarketGoodsMapper;
//import com.market.goods.dao.mapper.TimeTestMapper;
//import com.market.goods.dao.po.MarketGoodsPO;
//import com.market.goods.dao.po.TimeTestPO;
//import com.market.goods.producer.KafkaClusterProducer;
//import com.market.goods.web.vo.TestPageHelper;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.text.ParseException;
//import java.text.SimpleDateFormat;
//import java.util.Date;
//import java.util.List;
//import java.util.UUID;
//
//@Slf4j
//@Api(tags = "kafka相关服务")
//@RestController
//@RequestMapping("/test")
//public class KafkaController {
//
//    @Autowired
//    KafkaClusterProducer kafkaClusterProducer;
//
//    @Autowired
//    TimeTestMapper timeTestMapper;
//
//    @Autowired
//    MarketGoodsMapper marketGoodsMapper;
//
//    @ApiOperation("send")
//    @GetMapping("/send")
//    public void send(String message) {
//        kafkaClusterProducer.send(message);
//    }
//
//    /**
//     * 发送标准消息异步无阻塞
//     *
//     * @param message
//     */
//    @ApiOperation("sendToKafkaStandardMessageAsync")
//    @GetMapping("/sendToKafkaStandardMessageAsync")
//    public void sendToKafkaStandardMessageAsync(String message) {
//        kafkaClusterProducer.sendToKafkaStandardMessageAsync(message);
//    }
//
//
//    /**
//     * 发送标准消息同步有阻塞
//     *
//     * @param message
//     */
//    @ApiOperation("sendToKafkaStandardMessageSync")
//    @GetMapping("/sendToKafkaStandardMessageSync")
//    public void sendToKafkaStandardMessageSync(String message) {
//        kafkaClusterProducer.sendToKafkaStandardMessageSync(message);
//    }
//
//    /**
//     * 发送标准消息同步有阻塞
//     *
//     * @param message
//     */
//    @ApiOperation("executeInTransaction")
//    @GetMapping("/executeInTransaction")
//    public void executeInTransaction(String message) {
//        kafkaClusterProducer.executeInTransaction(message);
//    }
//
//    /**
//     * 发送标准消息同步有阻塞
//     *
//     * @param
//     */
//    @ApiOperation("addTime")
//    @GetMapping("/addTime")
//    public void addTime() throws ParseException {
//        add();
//
//    }
//
//    private void add() throws ParseException {
//        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        for (int k = 0; k < 1000; k++) {
//            int createTime = SuperRandom.getNum(2017, 2020);
//            Date time = SuperRandom.getTime(createTime);
//            String format = formatter.format(time);
//            log.info("addFormat={}",format);
//            TimeTestPO timeTestPO = new TimeTestPO();
//            timeTestPO.setUid(UUID.randomUUID().toString());
//            timeTestPO.setCreatedTime(time);
//            timeTestPO.setUpdatedTime(time);
////            timeTestMapper.insertSelective(timeTestPO);
//        }
//    }
//
//    @ApiOperation("queryAll")
//    @GetMapping("/queryAll")
//    public long queryAll() throws ParseException {
//        List<MarketGoodsPO> marketGoodsPOS = marketGoodsMapper.selectAll();
//        log.info("queryAllTimeTestPOS={}", marketGoodsPOS.size());
//        return marketGoodsPOS.size();
//    }
//
//    @ApiOperation("queryTime")
//    @GetMapping("/queryTime")
//    public void queryTime(String queryTime) throws ParseException {
//        log.info("queryTime={}", queryTime);
//        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        Date time = formatter.parse(queryTime);
//        TimeTestPO timeTestPO = new TimeTestPO();
//        timeTestPO.setCreatedTime(time);
//        List<TimeTestPO> timeTestPOS = timeTestMapper.queryTime(timeTestPO);
//    }
//
//    @ApiOperation("testPageHelper")
//    @GetMapping("/testPageHelper")
//    public Integer testPageHelper(TestPageHelper testPageHelper) throws ParseException {
//        log.info("testPageHelperTestPageHelper={}", testPageHelper);
//        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        String startTime = testPageHelper.getStartTime();
//        String endTime = testPageHelper.getEndTime();
//        Date startDate = formatter.parse(startTime);
//        Date endDate = formatter.parse(endTime);
//        PageHelper.startPage(testPageHelper.getPageNum(), testPageHelper.getPageSize(), "created_time desc");
//        List<TimeTestPO> timeTestPOS = timeTestMapper.getPage(startDate, endDate);
//        log.info("testPageHelpertimeTestPOS={}",timeTestPOS);
//        PageInfo pageInfo = new PageInfo(timeTestPOS);
//        // 获取列表总数
//        return (int) pageInfo.getTotal();
////        Example example = new Example(TimeTestPO.class);
////        // 查询条件
////        example.createCriteria().andBetween("createdTime",testPageHelper.getStartTime())
////        // 分页参数
//        // 获取分页列表数据
////        List<User> userList = timeTestMapper.
////        PageInfo pageInfo = new PageInfo(userList);
//        // 获取列表总数
////        int userCount = (int) pageInfo.getTotal();
//    }
//
//}
